package main

import (
	"fmt"
	"strconv"
	. "tasker"
	"time"
)

func initialize() {
	maxWorkers := 2
	maxQueue := 4
	//初始化一个调试者,并指定它可以操作的 工人个数
	dispatch := NewDispatcher(maxWorkers)
	JobQueue = make(chan Job, maxQueue) //指定任务的队列长度
	//并让它一直接运行
	dispatch.Run()
}
func main() {
	initialize()
	for i := 0; i < 10; i++ {
		p := Payload{
			fmt.Sprintf("玩家-[%s]", strconv.Itoa(i)),
		}
		JobQueue <- Job{
			Payload: p,
		}
		time.Sleep(time.Microsecond * 100)
	}
	close(JobQueue)
}
